package com.runa.monitor.platinterface.mqtt;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

public class MqttBaseController {

    private static final Map<String, MQTTConnector> connectorMap = new ConcurrentHashMap<>();

    public static  MQTTConnector getConnector(){
        return connectorMap.get("business_comm_system_");
    }

    public static  MQTTConnector getConnector(String clientId){
        return connectorMap.get(clientId);
    }

    public static void setConnector(String clientId,MQTTConnector connector){
        connectorMap.put(clientId,connector);
    }
}
